from task_queue import MyQueue, MysqlFind
import time

q =  MyQueue('myqueue', decode_responses=True)
sql = 'select email from user'
result = MysqlFind(sql).sql_select()

# 循环调用队列的push方法进行添加
for item in result:
    q.push(item.get("email"))
    print(item)
    # time.sleep(2)
